{
  "cells": [
    {
      "cell_type": "markdown",
      "id": "ee146f6f",
      "metadata": {},
      "source": [
        "架构组件：Producer/Broker/ConsumerGroup 关系\n",
        "核心机制：\n",
        "分区副本（ISR 队列）与消息投递语义\n",
        "消费者重平衡（Rebalance）触发条件\n",
        "面试重点：\n",
        "如何保证消息不丢失（生产者 / 消费者配置）\n",
        "分区数与消费者数的最佳配比\n",
        "实战场景：日志收集系统(kafka + Flume)"
      ]
    }
  ],
  "metadata": {
    "language_info": {
      "name": "python"
    }
  },
  "nbformat": 4,
  "nbformat_minor": 5
}